<?php
/**
 * @copyright meila.com
 * @author shaopu@
 * @name 
 * @param 
 *         $xxx = 作用
 * @static 
 *         XXX = 作用
 * 
 * 
 */
$dir = dirname(dirname(__FILE__));
include($dir.'/__queue_global.php');

class ml_mq_add_cmt_notice extends MqClass{
    const QUEUE_NAME = ML_QUEUENAME_ADD_CMT_NOTICE;
    private $oRds;
    /**
     * 注释
     *
     * @param array $message_data
     * array(
     *                        所接收的参数说明
     *        )
     * )
     */
    public function __construct($queue)
    {
        
        $this->oRds = new ml_model_rdsNotice();

        parent::__construct($queue);
    }
    
    public function run_job(){
        $arr = $this->src_data;
        $uid=$arr['uid'];
        
        $this->oRds->add_notice($uid , ml_model_rdsNotice::NTCTYPE_ADDCOMMENT);
        
        return true;
    }
}
ml_run_queue_check(ml_mq_add_cmt_notice::QUEUE_NAME);

$conf_array = ml_factory::load_standard_conf('redis');
$conf_array = $conf_array['meila_queue'];
$xblog_obj = new ml_mq_add_cmt_notice(new RsQueue(ml_mq_add_cmt_notice::QUEUE_NAME));
$argv[1]   = __FILE__;
$xblog_obj->setArgv($argv[1]);
$xblog_obj->execute();
?>